package com.wn.product.work1;

import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * @author yellow Docter
 * @date 2022 -11-02
 * @desc
 */
@Component
@Slf4j
public class Work01Product {

    // spring封装了 mq的操作 有模板类
    // RedisTemplate     操作redis的模板
    // RabbitTemplate    操作MQ的模板

    @Autowired
    private RabbitTemplate rabbitTemplate;

    /**
     * 发送消息的方法
     * @param msg
     */
    public void sendMsg(String msg){

        /**
         * 发送消息的方法：
         * 1、交换机   不给 使用默认的交换机
         * 2、路由key  (队列)
         * 3、发送的消息 (object 都是消息 )
         */
        rabbitTemplate.convertAndSend("","hello-queue",msg);
        log.info("消息发送成功:===>{}",msg);

    }

}
